package com.zhanghe.study.study_scala.akka.spark.common

/**
 * @author zh
 * @date 2021/5/10 16:51
 */
// worker注册信息
case class RegisterWorkerInfo(id: String, cpu: Int, ram: Int)
// Worker信息 保存在Master的hashmap中,用于管理worker
case class WorkerInfo(id: String, cpu: Int, ram: Int){
  // 上一次心跳时间
  var lastHeartBeat:Long = _
}

// worker注册成功，master返回一个RegisteredWorkerInfo对象
case object RegisteredWorkerInfo

// worker每隔一段时间由定时器发给自己的消息
case object SendHeartBeat

// worker每隔一段时间由定时器触发，向master发送一个协议消息
case class HeartBeat(id:String)

// master给自己发送一个触发检查超时Worker的信息
case object StartTimeOutWorker
// master检测worker，对于心跳超时的
case object RemoveTimeOutWorker
